package org.kumas.sgrpc.remoting.exchange;

import java.util.concurrent.CompletableFuture;

import org.kumas.sgrpc.remoting.ChannelHandler;
import org.kumas.sgrpc.remoting.RemotingException;

/**
 *
 * @author KumasZhang
 * @version 1.0
 * @since 2021-07-21 18:16
 */
public interface ExchangeHandler extends ChannelHandler {

    CompletableFuture<Object> reply(ExchangeChannel channel, Object request) throws RemotingException;

}
